package com.weichuang.ecommerce;

import java.io.ByteArrayInputStream;
import java.io.UnsupportedEncodingException;
import java.sql.Blob;
import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;

/**
 * <p>Copyright: All Rights Reserved</p>
 * <p>Company: 指点无限(北京)科技有限公司   http://www.weichuangwuxian.cn</p>
 * <p>Description: 自定义Blob类型字段数据映射 </p>
 * <p>Author:jmzhang/张际明, 16/09/20</p>
 */
public class Utf8BlobTypeHandler extends BaseTypeHandler<String> {
	//###指定字符集
	private static final String DEFAULT_CHARSET = "utf-8";
	
	public void setNonNullParameter(PreparedStatement ps, int i, String parameter, JdbcType jdbcType)
			throws SQLException {
		ByteArrayInputStream bis;
		try {
			//###把String转化成byte流
			bis = new ByteArrayInputStream(parameter.getBytes(DEFAULT_CHARSET));
			if (null == bis) {
				return;
			}
		}
		catch (UnsupportedEncodingException e) {
			throw new RuntimeException("Blob Encoding Error!");
		}
		ps.setBinaryStream(i, bis, parameter.length());
	}
	
	@Override
	public String getNullableResult(ResultSet rs, String columnName) throws SQLException {
		Blob blob = (Blob) rs.getBlob(columnName);
		if (null == blob || blob.length() < 1) {
			return null;
		}
		byte[] returnValue = null;
		if (null != blob) {
			returnValue = blob.getBytes(1, (int) blob.length());
		}
		if (null == returnValue) {
			return null;
		}
		try {
			//###把byte转化成string
			return new String(returnValue, DEFAULT_CHARSET);
		}
		catch (UnsupportedEncodingException e) {
			throw new RuntimeException("Blob Encoding Error!");
		}
	}
	
	public String getNullableResult(CallableStatement cs, int columnIndex) throws SQLException {
		Blob blob = (Blob) cs.getBlob(columnIndex);
		if (null == blob || blob.length() < 1) {
			return null;
		}
		byte[] returnValue = null;
		if (null != blob) {
			returnValue = blob.getBytes(1, (int) blob.length());
		}
		if (null == returnValue) {
			return null;
		}
		try {
			return new String(returnValue, DEFAULT_CHARSET);
		}
		catch (UnsupportedEncodingException e) {
			throw new RuntimeException("Blob Encoding Error!");
		}
	}
	
	@Override
	public String getNullableResult(ResultSet rs, int columnIndex) throws SQLException {
		// TODO Auto-generated method stub
		return null;
	}
}
